package utils;

import com.hw.model.MessageWapper;
import com.hw.model.MetricDataBody;
import org.apache.flink.streaming.api.functions.windowing.RichWindowFunction;
import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
import org.apache.flink.util.Collector;

public class ESDimTransferFunction extends RichWindowFunction<MetricDataBody, Iterable<MessageWapper>, String, TimeWindow> {
    @Override
    public void apply(String s, TimeWindow window, Iterable<MetricDataBody> input, Collector<Iterable<MessageWapper>> out) throws Exception {

    }
}
